package com.zhao.demo.unbound.demo02_calboundeddata

import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment

/**
 * Description: 无界流演示(使用无界流的api去分析处理离线的数据)
 * 即使是离线的数据,经由Flink的无界流的api,底层在计算离线数据的时候,也会将其当成
 * 流式的数据,一次装载到内存中密集型计算处理
 * <br/>
 * Copyright (c) ，2020 ， 赵 <br/>
 * This program is protected by copyright laws. <br/>
 * Date： 2020/11/26 14:11
 *
 * @author 柒柒
 * @version : 1.0
 */

object UnboundedFlowDemo1 {
  def main(args: Array[String]): Unit = {

    //1.执行的环境
    val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment

    //2.计算,输出
    import org.apache.flink.api.scala._

    env.readTextFile("a_input")
      .flatMap(_.split("\\s+"))
      .filter(_.nonEmpty)
      .map((_,1))
      .keyBy(0)
      .sum(1)
      .print("stream->")

    //3.启动
    env.execute(this.getClass.getSimpleName)
  }
}



















